f9650787ecc0774dedea9a1d50d43bf80321d133,bytetcc-core/src/main/java/org/bytesoft/bytetcc/CompensableTransactionImpl.java,CompensableTransactionImpl,fireNativeParticipantRecoveryCancel,#,733
Before Change
this.archive.setCancelled(true);
logger.info("{}| cancel: identifier= {}, resourceKey= {}, resourceXid= {}.",
ByteUtils.byteArrayToString(transactionContext.getXid().getGlobalTransactionId()),
current.getIdentifier(), current.getCompensableResourceKey(), current.getCompensableXid());
}
} catch (IllegalArgumentException rex) {
success = false;
After Change
ByteUtils.byteArrayToString(transactionContext.getXid().getGlobalTransactionId()),
ByteUtils.byteArrayToString(current.getIdentifier().getGlobalTransactionId()));
} else if (invocation == null) {
logger.error(
"{}| error occurred while cancelling service: {}, please check whether the params of method(compensable-service) supports serialization.",
ByteUtils.byteArrayToString(this.transactionContext.getXid().getGlobalTransactionId()),
ByteUtils.byteArrayToString(current.getIdentifier().getGlobalTransactionId()));
throw new IllegalArgumentException();
} else if (StringUtils.isNotBlank(invocation.getCancellableKey())) {
container.cancel(invocation);
} else {
this.archive.setCancelled(true);
logger.info("{}| cancel: identifier= {}, resourceKey= {}, resourceXid= {}.",
ByteUtils.byteArrayToString(this.transactionContext.getXid().getGlobalTransactionId()),
ByteUtils.byteArrayToString(current.getIdentifier().getGlobalTransactionId()),
current.getCompensableResourceKey(), current.getCompensableXid());
}
} catch (IllegalArgumentException rex) {
success = false;
logger.error(
"{}| error occurred while cancelling service: {}, please check whether the params of method(compensable-service) supports serialization.",
ByteUtils.byteArrayToString(this.transactionContext.getXid().getGlobalTransactionId()),
ByteUtils.byteArrayToString(current.getIdentifier().getGlobalTransactionId()));
} catch (RuntimeException rex) {
success = false;